package Queue;

import org.apache.activemq.command.ActiveMQTextMessage;
import org.springframework.context.ApplicationContext;
import org.springframework.context.support.ClassPathXmlApplicationContext;
import org.springframework.jms.core.JmsTemplate;
import org.springframework.jms.core.MessageCreator;

import javax.jms.*;


public class producer {
    public static void main(String[] args) {
        //    创建spring容器
        ApplicationContext activ=new ClassPathXmlApplicationContext("applicationContext-activemq-queue.xml");
//    从spring容器中获取JMSTemplate,这个对象是用来发送消息的
        JmsTemplate jmsTemplate = activ.getBean(JmsTemplate.class);
//        创建消息模式
        Destination destination=(Destination)activ.getBean("queueDestination");
//        使用Destination发送消息
        jmsTemplate.send(destination, new MessageCreator() {
            @Override
            public Message createMessage(Session session) throws JMSException {
                TextMessage activemq = new ActiveMQTextMessage();
                activemq.setText("你的剑就是我的剑");
                System.out.println("[生产者] 发送消息:"+activemq.getText()+"(成功)");
                return activemq;
            }
        });

    }
}
